package com.ledou44.rocketmqlearn;

import com.ledou44.rocketmqlearn.util.RocketMqUtil;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class RocketMqLearnApp {

    public static void main(String[] args) {
        SpringApplication.run(RocketMqLearnApp.class);
        RocketMqUtil.pushMessage("this is a new message!");
        RocketMqUtil.startConsumer();
    }

}
